package com.larry.spark.rdd.transform

import org.apache.spark.rdd.RDD
import org.apache.spark.{SparkConf, SparkContext}

object RDD_Oper_Sample {

  def main(args: Array[String]): Unit = {
    //TODO  使用spark

    val conf = new SparkConf().setMaster("local[*]").setAppName("rdd")
    val sc = new SparkContext(conf)

    val rdd: RDD[Int] = sc.makeRDD(1 to 10)

    //抽取：
    //抽取放回
    //抽取不放回
    //sample(
    //      withReplacement: Boolean,
    //      fraction: Double,
    //      seed: Long = Utils.random.nextLong
    //)
//    val rdd1 = rdd.sample(false, 0.5)
//    val rdd1 = rdd.sample(true, 0.5)
    //随机数种子
    val rdd1 = rdd.sample(false, 0.5,1)

    rdd1.collect().foreach(println)
    sc.stop()
  }
}
